type google.golang.org/grpc/internal/transport.serverHandlerTransport
16 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L77: st := &serverHandlerTransport{
handler_server.go#L127: type serverHandlerTransport struct {
handler_server.go#L156: func (ht *serverHandlerTransport) Close(err error) {
handler_server.go#L165: func (ht *serverHandlerTransport) RemoteAddr() net.Addr { return strAddr(ht.req.RemoteAddr) }
handler_server.go#L190: func (ht *serverHandlerTransport) do(fn func()) error {
handler_server.go#L199: func (ht *serverHandlerTransport) WriteStatus(s *Stream, st *status.Status) error {
handler_server.go#L260: func (ht *serverHandlerTransport) writePendingHeaders(s *Stream) {
handler_server.go#L267: func (ht *serverHandlerTransport) writeCommonHeaders(s *Stream) {
handler_server.go#L288: func (ht *serverHandlerTransport) writeCustomHeaders(s *Stream) {
handler_server.go#L304: func (ht *serverHandlerTransport) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
handler_server.go#L316: func (ht *serverHandlerTransport) WriteHeader(s *Stream, md metadata.MD) error {
handler_server.go#L344: func (ht *serverHandlerTransport) HandleStreams(startStream func(*Stream), traceCtx func(context.Context, string) context.Context) {
handler_server.go#L438: func (ht *serverHandlerTransport) runStream() {
handler_server.go#L449: func (ht *serverHandlerTransport) IncrMsgSent() {}
handler_server.go#L451: func (ht *serverHandlerTransport) IncrMsgRecv() {}
handler_server.go#L453: func (ht *serverHandlerTransport) Drain() {
The pages are generated with Golds v0.4.9. (GOOS=linux GOARCH=amd64)